package org.platform.lwc.kafka.config;

import org.platform.lwc.kafka.service.KafkaMessageSender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.KafkaTemplate;

@Configuration
public class KafkaConfiguration {
    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;


    @Bean
    public KafkaMessageSender kafkaMessageSender() {
        return new KafkaMessageSender(kafkaTemplate);
    }

}
